package com.paradox.rpc;

import io.netty.channel.Channel;

import java.util.Map;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ConcurrentHashMap;

public class Future<T> extends CompletableFuture<T> {
    public static Map<String,Future> responseReceiver=new ConcurrentHashMap<String,Future>();
    private Channel channel;

    public Future(Channel channel) {
        this.channel = channel;
    }

    public void receive(T t){
        super.complete(t);
    }
}
